//package com.atguigu.redis7.canel;
//
//import com.rabbitmq.client.Channel;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
//import org.springframework.amqp.support.AmqpHeaders;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.data.redis.core.RedisTemplate;
//import org.springframework.messaging.handler.annotation.Headers;
//import org.springframework.messaging.handler.annotation.Payload;
//import org.springframework.stereotype.Component;
//
//import java.io.IOException;
//import java.util.Map;
//
//@Component
//@Slf4j
//public class UserConsumer {
//
//    @Autowired
//    public RedisTemplate redisTemplate;
//
//    @RabbitListener(queues = "userUpdateQueue", containerFactory = "rabbitListenerContainerFactory")
//    public void userMessage(@Payload String id, @Headers Map<String, Object> headers, Channel channel) throws IOException {
//        Long t = (Long) headers.get(AmqpHeaders.DELIVERY_TAG);
//
//        channel.basicAck(t, false); //应答当前消息
//        try {
//            boolean flag = false;
//            for (int i = 0; i < 10; i++) {
//                try {
//                    //mysql更新  redis删除
//                    redisTemplate.delete(id);
//                    flag = true;
//                } catch (Exception e) {
//                    System.out.println("mq删除redis信息失败第" + i + "次");
//                    e.printStackTrace();
//                }
//                if (flag == true) {
//                    System.out.println("搞得");
//                    break;
//                }
//            }
//            //10次之后还没成功，发
//            if (flag == false) {
//                System.out.println("发送日志给运维");
//            }
//
//        } catch (Exception e) {
//            System.out.println("mq删除redis信息失败");
//            e.printStackTrace();
//        }
//    }
//}
